//package com.yuan.spring.messagequeue.redisqueue.newimpl;
//
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//import org.springframework.data.redis.connection.RedisConnectionFactory;
//import org.springframework.data.redis.listener.RedisMessageListenerContainer;
//
//import java.util.List;
//
///**
// * @author yuaneg 2018/12/3
// */
//@Configuration
//public class RedisListenConfig {
//
//    @Bean
//    public RedisListenProcessor redisListenProcessor() {
//        return new RedisListenProcessor();
//    }
//
//    @Bean
//    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory,
//                                                                       List<MessageListenerAdapterWrapper> messageListenerAdapterWrappers) {
//        RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
//        redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
//        messageListenerAdapterWrappers.forEach(messageListenerAdapterWrapper ->
//                redisMessageListenerContainer.addMessageListener(messageListenerAdapterWrapper, messageListenerAdapterWrapper.getPatternTopicList()));
//        return redisMessageListenerContainer;
//    }
//
//}
